/*
 * ProtectedQBounded.h
 *
 *  Created on: Jun 29, 2009
 *      Author: yoav
 */

#ifndef PROTECTEDQBOUNDED_H_
#define PROTECTEDQBOUNDED_H_

#include "ProtectedQ.h"


class ProtectedQBounded: public ProtectedQ {
public:
	ProtectedQBounded();
	void setLimit(int limit);
	virtual ~ProtectedQBounded();
	void push(void* n,Message* msg);
	Message * pop();

private:
	int limit;
	pthread_cond_t	queueCond;
};

#endif /* PROTECTEDQBOUNDED_H_ */
